package cron

//func OrderUnpaid(orderSn string, orderStatus int) {
//	c := cron.New(cron.WithSeconds())
//
//	c.AddFunc("0 */5 * * * ?", func() {
//		fmt.Println("订单")
//		o := model.Orders{}
//
//		id, err := o.QueryOrder(orderSn)
//		if err != nil {
//			fmt.Println(err)
//			return
//		}
//
//		fmt.Println(id.OrderStatus, orderStatus)
//
//		if int(id.OrderStatus) != orderStatus {
//			c.Stop()
//		} else {
//			err = o.UpdateOrderStatus(orderSn, 4)
//			if err != nil {
//				fmt.Println(err)
//				return
//			}
//
//		}
//	})
//	c.Start()
//	select {}
//}

//func SyncEsByList() {
//	c := cron.New(cron.WithSeconds())
//
//	c.AddFunc("0 */5 * * * ?", func() {
//		fmt.Println("同步任务启动")
//		s := mysql.SpikeProducts{}
//		list, err := s.QuerySpikeProductsList()
//		if err != nil {
//			return
//		}
//
//		fmt.Println(list)
//		es := pkg.SyncEs(list)
//		fmt.Println(es)
//	})
//	c.Start()
//	select {}
//}
